package com.bwie.kafka;

import com.bwie.common.pojo.dto.UserDto;
import com.bwie.common.pojo.po.UserPo;
import com.bwie.common.result.Result;
import lombok.extern.log4j.Log4j2;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;

@Component
@Log4j2
public class KafkaAuth {
    @KafkaListener(topics = "authKafka")
    public void authKafka(String username){
        System.out.println("====================这是kafka"+username);
    }
}
